from __future__ import absolute_import, unicode_literals
import os
from celery import Celery

# 1.设置环境变量
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'meiduo_mall.settings')
# 2.创建celery对象
app = Celery('meiduo')
# 3.加载配置文件
app.config_from_object('celery_tasks.config', namespace='meiduo_celery')
# 4.注册任务
"""
autodiscover_tasks 会自动发现包下面的tasks文件并自动执行函数，前提需要把包路径导入，如果tasks函数写在main主文件无需导入包路径（写在main文件中不方便后期维护）
"""
app.autodiscover_tasks(['celery_tasks.sms_code', 'celery_tasks.send_email'])

# @app.task(bind=True, name="debug")
# def debug_task(self, count):
#     import time
#     time.sleep(3)
#     print('Request: {}'.format(count))

#     return count

# 启动 celery -A celery_tasks.main worker -l info
